package com.fxkj.cloud.drms.domain.ts.service;

import com.fxkj.cloud.dbs.common.model.kv.TsKvEntry;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.ListenableFuture;

import java.util.List;
import java.util.UUID;

/**
 * <p>description: 遥测数据服务</p>
 * @author ww
 * @date 2025/3/18 9:17
 */
public interface TelemetryService {

    /**
     * 保存遥测数据并通知
     * @param deviceSerialNo 设备序列号
     * @param ts 遥测数据
     * @param callback 回调函数
     */
    void saveAndNotify(String deviceSerialNo, List<TsKvEntry> ts, FutureCallback<Void> callback);

}
